From: Jeroen van der Heijden <jeroen@transceptor.technology>
Date: Tue, 27 Mar 2018 09:27:07 +0000 (+0200)
Subject: add fflush
X-Git-Tag: archive/raspbian/2.0.44-1+rpi1~1^2~3^2~9^2~48
X-Git-Url: https://dgit.raspbian.org/%22http://www.example.com/cgi/success//%22http:/www.example.com/cgi/success/?a=commitdiff_plain;h=22c5e3dbbd31d0babcc4e38b6da5e013bb1efcd1;p=siridb-server.git

add fflush
---

diff --git a/src/siri/db/shard.c b/src/siri/db/shard.c
index cd76ffd0..03fc0d77 100644
--- a/src/siri/db/shard.c
+++ b/src/siri/db/shard.c
@@ -21,6 +21,7 @@
 #include <siri/db/series.h>
 #include <siri/db/shard.h>
 #include <siri/db/shards.h>
+#include <siri/db/points.h>
 #include <siri/optimize.h>
 #include <siri/err.h>
 #include <siri/file/pointer.h>
@@ -586,7 +587,8 @@ size_t siridb_shard_write_points(
 
     long int rc = fwrite(cdata, dsize, 1, fp);
     free(cdata);
-    if (rc != 1)
+
+    if (rc != 1 || fflush(fp))
     {
         ERR_FILE
         log_critical("Cannot write points to file '%s'", shard->fn);